package com.hc.rabbit;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component // 注入 Spring 容器
public class MailConsumer {

    // 监听名为 "email_queue" 的队列（根据实际队列名称修改）
    @RabbitListener(queues = "mail_queue")
    public void handleMailMessage(String message) {
        // 这里编写处理消息的逻辑（例如解析消息、发送邮件等）
        System.out.println("收到消息：" + message);

        // 模拟处理耗时（如调用邮件发送接口）
        try {
            Thread.sleep(1000); // 休眠 1 秒，模拟处理过程
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        System.out.println("消息处理完成，已删除");
    }
}